from celery import Celery
import os
from django.conf import settings

# 配置环境变量 celery的worker进程是脱离django启动, 但是依赖其配置文件
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'p6_421.settings')

# 创建celery应用
app = Celery('myworker')

# 配置app
app.conf.broker_url = 'redis://:@127.0.0.1:6379/5'    # 相当于数据结构中的队列, Broker把任务暂时放到队列中，等待Worker来处理。
app.conf.result_backend = 'redis://:@127.0.0.1:6379/6'  # Backend 用于保存任务的执行结果

# 发现任务函数   autodiscover_tasks自动发现任务
app.autodiscover_tasks(settings.INSTALLED_APPS)

